package com.haishuibutian.rocketmqconsumer.rocketmq;

@MQConsumerComponent(tags = "zhijjie")
public class TopicYangTagZhijjieListener implements MQConsumerHandler<String> {

    @Override
    public boolean handler(String message) throws Exception {
        System.out.println(message);
        return true;
    }

    @Override
    public Class<String> getClazz() {
        return String.class;
    }
}
